package com.doitedu.core

import scala.io.Source

/**
 * @Date: 22.6.28 
 * @Author: HANGGE
 * @qq: 598196583
 * @Tips: 学大数据 ,到多易教育
 * @Description:
 */
object C04TestIterator {
  def main(args: Array[String]): Unit = {
    val source = Source.fromFile("data/word.txt")
    val lines: Iterator[String] = source.getLines()

    val rdd1 = lines.map(e => {
      println("第一步.......")
      e.toUpperCase()
    })


   val rdd2 =  rdd1.map(e=>{
      println("第二步.......")
      e.split("\\s+")
    })

    val rdd3: Iterator[String] = rdd2.flatMap(arr =>{
      println("第三步.......")
      arr
    } )

    /**
     *    println("第一步.......")
     *    rintln("第二步.......")
          println("第三步.......")
          e.toUpperCase()
          e.split("\\s+")
          arr
     *
     *
     */
    //     f =
    // 执行逻辑链条的封装
    rdd3.foreach(e=>println(e))


  }

}
